package test

import org.apache.spark.{SparkConf, SparkContext}

object demo2 {
  def main(args: Array[String]): Unit = {
    //  (1)创建RDD
    var conf = new SparkConf().setAppName("myapp").setMaster("local")
    var sc = new SparkContext(conf)
    //    创建RDD
    var a1 = Array(2, 3, 4, 5, 6)
    var rdd = sc.parallelize(a1)
    print("打印内容:" + rdd)

    var rdd1 = sc.makeRDD(a1)
    print("打印内容:" + rdd1)

    var rdd2 = sc.textFile("data/input/words.txt")
    print("打印内容rdd2:" + rdd2)
    print(rdd2.collect)
    rdd2.collect().foreach(println)
  }

}
